cf7ef936d20b98482a48926a194772c66d3234c1,hbase-server/src/main/java/org/apache/hadoop/hbase/tool/Canary.java,RegionMonitor,sniff,#,464
Before Change
*/
private void sniff() throws Exception {
for (HTableDescriptor table : admin.listTables()) {
Canary.sniff(admin, sink, table);
}
}
After Change
List<Future<Void>> taskFutures = new LinkedList<Future<Void>>();
for (HTableDescriptor table : admin.listTables()) {
if (admin.isTableEnabled(table.getTableName())) {
taskFutures.addAll(Canary.sniff(admin, sink, table, executor));
}
}
return taskFutures;